217c49a8c550422f0685099aa797aaa77e513605,src/main/java/com/continuuity/data/operation/ttqueue/TTQueueNewOnVCTable.java,TTQueueNewOnVCTable,invalidate,#QueueEntryPointer#number#,145

Before Change


                   cleanWriteVersion, new EntryMeta(EntryMeta.EntryState.INVALID).getBytes());
    // Delete data since it's invalidated
    this.table.delete(rowName, ENTRY_DATA, cleanWriteVersion);
    if (TRACE) log("Invalidated " + entryPointer);
  }

  @Override

After Change


                   cleanWriteVersion, new EntryMeta(EntryMeta.EntryState.INVALID).getBytes());
    // Delete data since it's invalidated
    this.table.delete(rowName, ENTRY_DATA, cleanWriteVersion);
    if (LOG.isTraceEnabled()) {
      LOG.trace("Invalidated " + entryPointer);
    }
  }